1 files changed, 58 insertions, 0 deletions
diff --git a/envshare/pages/api/v1/secret/[id].ts b/envshare/pages/api/v1/secret/[id].ts
new file mode 100644
index 0000000..8b5f082
--- /dev/null
+++ b/envshare/pages/api/v1/secret/[id].ts
@@ -0,0 +1,58 @@
+import { NextRequest, NextResponse } from "next/server";
+import { Redis } from "@upstash/redis";
+import { z } from "zod";
+
+const responseValidation = z.union([
+  z.object({
+    data: z.object({
+      remainingReads: z.number().int().optional(),
+      secret: z.string(),
+    }),
+  }),
+  z.object({
+    error: z.string(),
+  }),
+]);
+
+const redis = Redis.fromEnv();
+export default async function handler(req: NextRequest): Promise<NextResponse> {
+  try {
+    if (req.method !== "GET") {
+      return NextResponse.json({ error: "Method Not Allowed" }, { status: 405 });
+    }
+    const id = new URL(req.url).searchParams.get("id");
+    if (!id) {
+      return NextResponse.json({ error: "Missing `id` parameter" }, { status: 400 });
+    }
+
+    const redisKey = ["envshare", id].join(":");
+
+    const [data, _] = await Promise.all([
+      await redis.hgetall<{ secret: string; remainingReads: number | null }>(redisKey),
+      await redis.incr("envshare:metrics:reads"),
+    ]);
+
+    if (!data) {
+      return NextResponse.json({ error: "Not Found" }, { status: 404 });
+    }
+    if (data.remainingReads !== null && data.remainingReads < 1) {
+      await redis.del(redisKey);
+      return NextResponse.json({ error: "Not Found" }, { status: 404 });
+    }
+
+    let remainingReads: number | null = null;
+    if (data.remainingReads !== null) {
+      // Decrement the number of reads and return the remaining reads
+      remainingReads = await redis.hincrby(redisKey, "remainingReads", -1);
+    }
+
+    return NextResponse.json({ data: { secret: data.secret, remainingReads: remainingReads ?? undefined } });
+  } catch (e) {
+    console.error(e);
+    return NextResponse.json({ error: "Internal Server Error" }, { status: 500 });
+  }
+}
+
+export const config = {
+  runtime: "edge",
+};